/**
 * 处理sql请求
 * reqSqlData(sql, data)
 * sql:必传参数，执行的sql语句
 * data:非必传参数，站位符所需要的数据,可以是：string、number，array
 */
const db = require('./index');
function reqSqlData(sql, data = undefined) {
  return new Promise((resolve, reject) => {
    db.query(sql, data, (err, results) => {
      // 处理sql语句的错误
      if (err) return reject(err);
      if (results instanceof Array) { // 查询数据,返回的是一个对象数组
        results.length > 0
          ? resolve(results)
          : resolve(err)
      } else if (results instanceof Object) { // 修改数据，返回的是一个对象，
        results.affectedRows !== 1
          ? reject(err)
          : resolve(results.affectedRows)
      } else {
        reject(err)
      }
    })
  })
}

module.exports = reqSqlData